package com.ai.smlcore.service.common;

import com.ai.frame.bean.InputObject;
/**
 * 异步消息服务类
 */
public interface IQueueService {
	/**
	 * 将内容放入消息队列
	 * @param topic 主题
	 * @param key 业务标记
	 * @param inputObject 内容对象
	 * @return
	 * @throws Exception
	 */
	public boolean sendMsg2MQ(String topic, String key, InputObject inputObject) throws Exception;
	
	/**
	 * 将内容放入消息队列
	 * @param topic 主题
	 * @param key 业务标记
	 * @param value 内容对象(可以序列化的对象)
	 * @return
	 * @throws Exception
	 */
	public boolean sendMsg2MQ(String topic, String key, String value) throws Exception;
	
	/**
	 * 将内容放入消息队列
	 * @param topic 主题
	 * @param key 业务标记
	 * @param inputObject 内容对象
	 * @return
	 * @throws Exception
	 */
	public boolean saveOrderToRedisMq(String topicExceOrder, String string,
			InputObject inputObject) throws Exception;
	
}
